package com.jch.hbase;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.DataSource;

public class WordCount {

    public static void main(String[] args) {

        //创建环境
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();


        String path="data/data.txt";
        //
        DataSource<String> source = env.readTextFile(path);



        


    }


}
